37297389d504a031e2adbf5ab9dae4f7b430e766,src/test/java/org/springframework/integration/kafka/listener/DefaultConnectionTests.java,DefaultConnectionTests,testFetchPartitionMetadata,#,51
Before Change
public void testFetchPartitionMetadata() throws Exception {
createTopic(TEST_TOPIC, 1, 1, 1);
Connection brokerConnection =
new DefaultConnection(getKafkaRule().getBrokerAddresses().get(0), "client", 64*1024, 3000, 1, 10000);
Partition partition = new Partition(TEST_TOPIC, 0);
Result<Long> result = brokerConnection.fetchInitialOffset(-1, partition);
Assert.assertEquals(0, result.getErrors().size());
After Change
public void testFetchPartitionMetadata() throws Exception {
createTopic(TEST_TOPIC, 1, 1, 1);
Connection brokerConnection =
new DefaultConnection(getKafkaRule().getBrokerAddresses()[0], "client", 64*1024, 3000, 1, 10000);
Partition partition = new Partition(TEST_TOPIC, 0);
Result<Long> result = brokerConnection.fetchInitialOffset(-1, partition);
Assert.assertEquals(0, result.getErrors().size());